# -*- coding: utf-8 -*-
from airflow.operators.dummy_operator import DummyOperator
from ..yl_oms_oms_order import jms_ods__yl_oms_oms_order
from ..yl_oms_oms_waybill import jms_ods__yl_oms_oms_waybill
# from ..yl_oms_oms_order_back_detail import jms_ods__yl_oms_oms_order_back_detail
# from ..yl_oms_waybill_deliver_count import jms_ods__yl_oms_waybill_deliver_count
# from ..yl_oms_waybill_out_count import jms_ods__yl_oms_waybill_out_count
from ..yl_oms_interceptorpiece import jms_ods__yl_oms_interceptorpiece
# from ..yl_oms_interceptorrecord import jms_ods__yl_oms_interceptorrecord
from ..oms_waybill_extend import jms_ods__oms_waybill_extend
from ..yl_oms_dispatch_waybill import jms_ods__yl_oms_dispatch_waybill


ods_oms_total_task_tag = DummyOperator(
    task_id='ods_oms_total_task_tag',
    email=['chenhongping@yl-scm.com','yl_bigdata@yl-scm.com'],
    retries=0,
    priority_weight=0,
)

ods_oms_total_task_tag << [
    jms_ods__yl_oms_oms_order,
    jms_ods__yl_oms_oms_waybill,
    # jms_ods__yl_oms_oms_order_back_detail,
    # jms_ods__yl_oms_waybill_deliver_count,
    # jms_ods__yl_oms_waybill_out_count,
    jms_ods__yl_oms_interceptorpiece,
    # jms_ods__yl_oms_interceptorrecord,
    jms_ods__oms_waybill_extend,
    jms_ods__yl_oms_dispatch_waybill,
]


